9c249f987be2851366f8c014557d3539d9b62137,src/main/java/org/jetlang/web/WebSocketConnection.java,WebSocketConnection,scheduleWithFixedDelay,#Runnable#number#number#TimeUnit#,159

Before Change



    @Override
    public Disposable scheduleWithFixedDelay(Runnable runnable, long l, long l1, TimeUnit timeUnit) {
        Disposable disposable = readFiber.scheduleWithFixedDelay(runIfActive(runnable), l, l1, timeUnit);
        addIfActive(disposable);
        return disposable;
    }

After Change



    @Override
    public Disposable scheduleWithFixedDelay(Runnable runnable, long initialDelay, long delay, TimeUnit timeUnit) {
        return register(readFiber.scheduleWithFixedDelay(runIfActive(runnable), initialDelay, delay, timeUnit));
    }

    private Disposable register(Disposable disposable) {